#!/usr/bin/python
# -*- coding:utf-8 -*-
from kafka import SimpleClient
from kafka import SimpleConsumer

kafkaclient = SimpleClient("linux1:9092")

consumer = SimpleConsumer(kafkaclient,"topic_group", "topic_kafka")
for msg in consumer:
    print(msg)